package c.e.a.b.g;

import java.util.concurrent.Executor;
import javax.annotation.concurrent.GuardedBy;

public final class p<TResult> implements x<TResult> {
    public final Executor a;
    public final Object b = new Object();
    @GuardedBy("mLock")
    public b c;

    public p(Executor executor, b bVar) {
        this.a = executor;
        this.c = bVar;
    }

    /* JADX WARNING: Missing block: B:10:0x0010, code skipped:
            r1.a.execute(new c.e.a.b.g.q(r1));
     */
    public final void a(c.e.a.b.g.g r2) {
        /*
        r1 = this;
        r2 = r2.i();
        if (r2 == 0) goto L_0x001e;
    L_0x0006:
        r2 = r1.b;
        monitor-enter(r2);
        r0 = r1.c;	 Catch:{ all -> 0x001b }
        if (r0 != 0) goto L_0x000f;
    L_0x000d:
        monitor-exit(r2);	 Catch:{ all -> 0x001b }
        return;
    L_0x000f:
        monitor-exit(r2);	 Catch:{ all -> 0x001b }
        r2 = r1.a;
        r0 = new c.e.a.b.g.q;
        r0.m1539init(r1);
        r2.execute(r0);
        goto L_0x001e;
    L_0x001b:
        r0 = move-exception;
        monitor-exit(r2);	 Catch:{ all -> 0x001b }
        throw r0;
    L_0x001e:
        return;
        */
        throw new UnsupportedOperationException("Method not decompiled: c.e.a.b.g.p.a(c.e.a.b.g.g):void");
    }
}
